// 云函数入口文件
const cloud = require('wx-server-sdk')

cloud.init({
  env: cloud.DYNAMIC_CURRENT_ENV
})
// 数据库操作对象
const db = cloud.database()

// 云函数入口函数
exports.main = async (event, context) => {
  const wxContext = cloud.getWXContext()

  console.log("网点编码--->" +event.websitecode);
  console.log("原始密码--->" +event.origin_ps);
  console.log("新密码--->" +event.new_ps);
  var result = await db.collection('es_website').where({
    wdbm:event.websitecode,
    mm:event.origin_ps
  }).get().then(res=>{
    return res.data.length !=0
  }).catch(err=>{
    return false;
  })
  if (result) {
    var msg = await db.collection('es_website').where({
      wdbm:event.websitecode
    }).update({
      data:{
        mm:event.new_ps
      }
    }).then(res=>{
      console.log(res)
      return res.stats.updated>0 ? '更新密码成功' :'更新密码失败'
    }).catch(err=>{
      return '更新密码失败'
    })

    return {
      msg:msg
    }
  } else {
    return {
      msg:'原密码错误'
    }
  }
}